package com.ftwj.demo.modular.dao;

import org.springframework.stereotype.Repository;

import com.ftwj.demo.base.common.BaseDao;
import com.ftwj.demo.modular.entity.ScheduleJobBean;

/**
*
* <p>Title: ScheduleJobDao</p>  
* <p>Description: 描述</p>
* <p>Copyright: Copyright (c) 2020 </p>  
* <p>Company: 兰州飞天网景信息产业有限公司</p>    
* @author WangSli
* @date 2020年04月16日 14:02:35
* @version V1.0
*/
@Repository
public class ScheduleJobDao extends BaseDao<ScheduleJobBean, Integer> {

	/**
	 * <p>Title: pauseAll</p>  
	 * <p>Description: 暂停正在运行中的调度器</p>   
	 * @author HeYang
	 * @date 2020年4月16日  
	 * @version 1.0
	 */
	public int pauseAll() {
		String sql = "UPDATE tb_schedule_job SET state = 0 WHERE state = 1";
		return jtl.update(sql);
	}

	/**
	 * <p>Title: restartAll</p>  
	 * <p>Description: 重启所有暂停中的调度器</p>   
	 * @author HeYang
	 * @date 2020年4月16日  
	 * @version 1.0
	 */
	public int restartAll() {
		String sql = "UPDATE tb_schedule_job SET state = 1 WHERE state = 0";
		return jtl.update(sql);
	}

	/**
	 * <p>Title: queryCountByNameAndGroup</p>  
	 * <p>Description: 通过名称与分组验重</p>  
	 * @param entity
	 * @author HeYang
	 * @date 2020年5月13日  
	 * @version 1.0
	 */
	public int queryCountByNameAndGroup(ScheduleJobBean entity) {
		String sql = "SELECT COUNT(1) FROM tb_schedule_job WHERE state = 1 AND name = ? AND group = ? ";
		return jtl.queryForObject(sql, int.class, new Object[] {entity.getName(),entity.getGroup()});
	}
	

}
